package com.xiaoke.mapreduce.topn;

import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.mapreduce.Partitioner;

public class TPartitioner extends Partitioner<TKey, IntWritable> {

    //1,不能太复杂。。。
    //partitioner  按  年，月  分区  -》  分区 > 分组  按 年分区！！！！！！
    //分区器潜台词：满足  相同的key获得相同的分区号就可以~！

    @Override
    public int getPartition(TKey tKey, IntWritable intWritable, int numPartitions) {
        //numPartitions 数量来自配置项 mapreduce.task.partition
        return tKey.getYear() % numPartitions;
    }
}
